package com.tfswx.serialport;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.LinkedBlockingQueue;

/**
 * @author ricky
 * @date 2021/7/21
 */

public class TestClas {

    private static final LinkedBlockingQueue<Byte> bufList = new LinkedBlockingQueue<>();

    public static void main(String[] args) throws InterruptedException {
        // 76 40 48 48 44 52 48 44 49 41 69
        bufList.put((byte) 76);
        bufList.put((byte) 40);
        bufList.put((byte) 48);
        bufList.put((byte) 48);
        bufList.put((byte) 44);
        bufList.put((byte) 52);
        bufList.put((byte) 48);
        bufList.put((byte) 44);
        bufList.put((byte) 49);
        bufList.put((byte) 41);
        bufList.put((byte) 69);

        List<Byte> temp = new ArrayList<>();
        while (true) {
            Byte poll = bufList.poll();
            temp.add(poll);
            if (poll == 69) {
                byte[] bytes = new byte[temp.size()];
                for (int i = 0; i < temp.size(); i++) {
                    bytes[i] = temp.get(i);
                }
                System.out.println(new String(bytes));
                break;
            }
        }
    }
}
